1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

db.text.aggregate(

 // Initial document match (uses index, if a suitable one is available)

 [

 { $match: {

  _id : ObjectId("5ca95b4bfb60ec43b5dd0db5")

 }},

 // Expand the scores array into a stream of documents

 { $unwind: '$tweet_list' },

  { $match: {

   'tweet_list.timestamp_ms': '1451841845660'

  }},

 // Sort in descending order

 { $sort: {

  'tweet_list.timestamp_ms': 1

 }}

 ]

)

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

Aggregation agg = Aggregation.newAggregation(

  Aggregation.match(Criteria.where("_id").is(id)),

  Aggregation.unwind("tweet_list"),

  Aggregation.sort(Sort.Direction.ASC,"tweet_list.timestamp_ms"),

  Aggregation.project("tweet_list.timestamp_ms","tweet_list.text","tweet_list.created_at")

);

AggregationResults<JSONObject> results = mongoTemplate.aggregate(agg, "text", JSONObject.class);

//System.out.println("results"+results.getRawResults()); //获取到的结果是document

//String res = results.getRawResults();

String json = com.mongodb.util.JSON.serialize(results.getRawResults());

System.out.println("JSON serialized Document: " + json);

JSONObject jso= JSON.parseObject(json);

JSONArray resultss=jso.getJSONArray("results");

System.out.println(resultss);